package com.abocode.aichat.server.context.pipeline;

import com.abocode.aichat.data.Entity;
import com.abocode.aichat.server.context.delivery.reply.Replies;
import com.abocode.aichat.data.MessageStanza;
import io.netty.channel.Channel;

public interface MessagePipeline {
    void sendMessageToChannel(String replyStr, String domain);

    Replies messages(Channel channel, Entity jidEntity);

    void confirm(Entity entity, Object msgId);

    void push(Entity toEntity, MessageStanza stanza);
}
